package com.sys.SysWaterQuality.controller;

import com.sys.SysWaterQuality.service.SysWebHookService;
import com.sys.common.annotation.Anonymous;
import com.sys.common.core.controller.BaseController;
import com.sys.common.core.domain.AjaxResult;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;

/**
 * 水质数据WebHook控制器（规则引擎版本）
 */
@Anonymous
@RestController
@RequestMapping("/webHook/v2")
@RequiredArgsConstructor
public class SysWebHookController extends BaseController {

    private final SysWebHookService sysWebHookService;

    /**
     * 接收水质数据 - 规则引擎版本
     * 三步流程：
     * 1. 数据获取和处理
     * 2. 规则引擎对比
     * 3. 数据入库
     */
    @PostMapping("/notify")
    public AjaxResult notify(@RequestBody Map<Object, Object> body) {
        return sysWebHookService.processWaterQualityData(body);
    }
}